package com.chiaching.framwork.core.handler.mq;

import com.chiaching.framwork.domian.constant.Action;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
import org.apache.rocketmq.common.message.MessageExt;

/**
 *
 * 自定义mq消费监听消费实现
 * @author jiajing.he
 * @date 2021/7/19 上午11:26
 */
public interface DefaultMessageListener {

    /**
     * @param message
     * @return
     */
    Action consume(final MessageExt message);
}
